package com.hong.spring.listener;

import com.alibaba.fastjson.JSONObject;
import com.hong.spring.api.IUserService;
import com.hong.spring.entity.User;
import com.hong.spring.utils.DataResponse;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author: csh
 * @Date: 2021/3/16 11:14
 * @Description:用户监听
 */
@Log4j2
@Component
public class UserListener implements ConsumerCommon {

    @Autowired
    private IUserService userService;

    @Override
    public void handleData(byte[] data) {
        if(null!=data && data.length>0){
            String str = new String(data);
            log.info("获取的用户信息{}", str);
            User user = JSONObject.parseObject(str, User.class);
            DataResponse <Boolean> save = userService.save(user);
            if(save==null || save.getData()==null || !save.getData()){
                log.info("添加失败，原因{}",JSONObject.toJSONString(save));
            }
        }else{
            log.info("获取为空!");
        }

    }
}
